package com.uptown.matrix.core.template;

import com.uptown.matrix.core.annotation.MatrixMessageListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {


    @MatrixMessageListener(
            streamKey = "uptown",
            consumerGroup = "uptown_group",
            componentType = "kafka",
            bootServer="192.168.1.51:9092")
    public void abc(String message) {

        System.out.println("abc监听到数据 -> " + message);
    }

}
